7fb3ffefb14d5d54822561284bf7768e4d6b344a,hazelcast/src/main/java/com/hazelcast/cache/impl/HazelcastServerCacheManager.java,HazelcastServerCacheManager,enableStatisticManagementOnOtherNodes,#String#boolean#boolean#,85
Before Change
if (!member.localMember()) {
final CacheManagementConfigOperation op = new CacheManagementConfigOperation(cacheNameWithPrefix, statOrMan,
enabled);
nodeEngine.getOperationService().invokeOnTarget(CacheService.SERVICE_NAME, op, member.getAddress());
}
}
}
After Change
private void enableStatisticManagementOnOtherNodes(String cacheName, boolean statOrMan, boolean enabled) {
final String cacheNameWithPrefix = getCacheNameWithPrefix(cacheName);
final Collection<MemberImpl> members = nodeEngine.getClusterService().getMemberList();
final Collection<Future> futures = new ArrayList<Future>();
for (MemberImpl member : members) {
if (!member.localMember()) {
final CacheManagementConfigOperation op = new CacheManagementConfigOperation(cacheNameWithPrefix, statOrMan,
enabled);
final Future future = nodeEngine.getOperationService()
.invokeOnTarget(CacheService.SERVICE_NAME, op, member.getAddress());
futures.add(future);
}
}
try {
FutureUtil.waitWithDeadline(futures, CacheProxyUtil.AWAIT_COMPLETION_TIMEOUT_SECONDS, TimeUnit.SECONDS);
} catch (TimeoutException e) {
logger.warning(e);
}